package com.chis.jmdatatimer.comm;

import org.apache.kafka.common.serialization.Deserializer;

import java.util.Map;

/**
 * @Description kafka序列化方法
 * @Company zwx
 * @author huangzh
 * @version 2018年6月28日
 */
public class DecodeingKafka implements Deserializer<Object> {

    @Override
    public void configure(Map<String, ?> map, boolean b) {

    }

    @Override
    public Object deserialize(String s, byte[] bytes) {
        return JedisSerializeUtil.unserialize(bytes);
    }

    @Override
    public void close() {

    }

    public DecodeingKafka() {
    }
}
